package com.jacken.mars.commons.mq.base.mq.consumer;

import org.apache.rocketmq.client.exception.MQClientException;

/**
 * @author wangqinag
 * @version 1.0
 * @date 2021/1/4 10:28
 */
public interface ConsumerListener {

    /**
     * 初始化
     */
    void init() throws MQClientException;
}
